package com.springcloud.test;

import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;

/**
 * @Desc 使用消费组实现消息消费的负载均衡
 * <p>
 * 分别运行上面实现的生产者与消费者，其中消费者我们启动多个实例。
 * 通过控制台，我们可以发现每个生产者发出的消息，会被启动的消费者以轮询的方式进行接收和输出
 * 这样就会每一次消息生产者产生消息，只会被该消费组中的一个消费者消费，不会出现重复消费问题
 * ----------------
 * @CLASS_NAME: SinkApplication
 * ----------------
 * @Author jovi
 * ----------------
 * @Date 2020-03-27 16:02
 */
@SpringBootApplication
public class SinkReceiveApplication {
    public static void main(String[] args) {
        SpringApplication.run(SinkReceiveApplication.class, args);
    }
}
